package com.songlanyun.modules.rabbitmq.mq.producer.impl;

import com.songlanyun.modules.rabbitmq.DelayedConstant;
import com.songlanyun.modules.rabbitmq.MqConstant;
import com.songlanyun.modules.rabbitmq.mq.producer.SendUserMsgService;
import com.songlanyun.modules.rabbitmq.service.SendMsgService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service("sendUserMsgService")
public class SendUserMsgServiceImpl implements SendUserMsgService {

    @Resource
    private SendMsgService sendMsgService;

    @Override
    public void regSuccessSendMsg(Long userId) {
        sendMsgService.send(MqConstant.UserRegSuccessConstant.USER_REG_SUCCESS_EXCHANGE, MqConstant.UserRegSuccessConstant.USER_REG_SUCCESS_ROUTER
                , userId.toString());
    }
}
